package com.maksdu.LactiveMQ.listener;

import com.maksdu.LactiveMQ.domain.Message;

public interface LativeRetryListener extends LactiveListener {

	/**
	 * 判断消息的重试位是否被标记
	 * @param message
	 * @return
	 */
	boolean isRetry(Message message);
	
	/**
	 * 消息重发机制
	 * @param message
	 */
	void reSend(Message message);
}
